package com.example.message.constant;

/**
 * mq 常量类
 */
public class MessageConstant {

    //生产者-集群消息主题
    public static final String CLUSTER_MESSAGE_OUTPUT = "cluster-out-0";
    //生产者-广播消息主题
    public static final String BROADCAST_MESSAGE_OUTPUT = "broadcast-out-0";
    //生产者-延时消息主题
    public static final String DELAYED_MESSAGE_OUTPUT = "delay-out-0";

    //消费者-集群消息主题
    public static final String CLUSTER_MESSAGE_INPUT = "cluster-in-0";
    //消费者-广播消息主题
    public static final String BROADCAST_MESSAGE_INPUT = "broadcast-in-0";
    //消费者-延时消息主题
    public static final String DELAYED_MESSAGE_INPUT = "delay-in-0";
}
